# -*- coding: utf-8 -*-
from apscheduler.schedulers.blocking import BlockingScheduler
from stock_spider import get_stock_dapan_spider,get_stock_categroy,get_stock_history_data,get_stock_timely
"""
启动文件 使用后apscheduler 调度定时任务
"""

if __name__ == '__main__':
    scheduler = BlockingScheduler()

    # 大盘数据3秒更新一次
    scheduler.add_job(get_stock_dapan_spider, 'interval', seconds=5,max_instances=10)
    # 分类信息每天一次
    scheduler.add_job(get_stock_categroy, 'interval', hours=24)
    # 历史数据两天一次
    scheduler.add_job(get_stock_history_data, 'interval', hours=48)
    # 及时数据2秒一次
    scheduler.add_job(get_stock_timely, 'interval', seconds=2,max_instances=10)

    try:
        scheduler.start()
    except (KeyboardInterrupt, SystemExit):
        pass